dd3006686fb35721e494fc9d9a21371cb7547cea,performance/src/main/java/com/continuuity/performance/runner/LoggingPerformanceTest.java,LoggingPerformanceTest,testApp,#,18

Before Change


      BenchmarkRuntimeMetrics sourceFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp", "LoggingFlow",
                                                                                             "source");

      System.out.println("Number of events generated by source flowlet = " + sourceFlowletMetrics.getProcessed());

      sourceFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);

      System.out.println("Number of events generated by source flowlet = " + sourceFlowletMetrics.getProcessed());

      BenchmarkRuntimeMetrics loggerFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp", "LoggingFlow",
                                                                                             "logger");

      System.out.println("Number of events processed by logger flowlet = " + loggerFlowletMetrics.getProcessed());

      loggerFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);

      System.out.println("Number of events processed by logger flowlet = " + loggerFlowletMetrics.getProcessed());

    } finally {
      applicationManager.stopAll();

After Change


      BenchmarkRuntimeMetrics sourceFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp",
                                                                                             "LoggingFlow", "source");

      System.out.println(String.format("Number of events generated by source flowlet = %d",
                                       sourceFlowletMetrics.getProcessed()));

      sourceFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);

      System.out.println(String.format("Number of events generated by source flowlet = %d",
                                       sourceFlowletMetrics.getProcessed()));

      BenchmarkRuntimeMetrics loggerFlowletMetrics = BenchmarkRuntimeStats.getFlowletMetrics("LoggingApp",
                                                                                             "LoggingFlow", "logger");

      System.out.println(String.format("Number of events processed by logger flowlet = %d",
                                       loggerFlowletMetrics.getProcessed()));

      loggerFlowletMetrics.waitForProcessed(numEvents, 120, TimeUnit.SECONDS);

      System.out.println(String.format("Number of events processed by logger flowlet = %d",
                                       loggerFlowletMetrics.getProcessed()));

    } finally {
      applicationManager.stopAll();